from KafkaHelper import KafkaHelper

helper = KafkaHelper()
helper.publish('hello world')